package com.muchfish.reactor.api;

import reactor.core.publisher.Flux;

public class ReactorConditionalOperatorsExample {
    public static void main(String[] args) {
        Flux<Integer> empty = Flux.range(1, 0);
        Flux<Integer> source = Flux.range(1, 5);

        // 如果数据流为空，则切换到另一个数据流
        empty.switchIfEmpty(Flux.range(6, 3))
                .subscribe(System.out::println); // 输出: 6,7,8

        // 使用 filter 过滤元素
        source.filter(x -> x % 2 == 0)
                .subscribe(System.out::println); // 输出: 2, 4
    }
}
